package com.bougaga.samplespringcloud.kafka.consumer.receiver;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

import com.bougaga.samplespringcloud.kafka.consumer.pipeline.Sink;


@EnableBinding(Sink.class)  
public class KafkaReceiver {
	private final Logger logger = LoggerFactory.getLogger(KafkaReceiver.class);  
	  
    @StreamListener(Sink.INPUT_1)  
    private void receive(String vote) {  
        logger.info("receive message : " + vote);  
    }  
}
